package com.youxin.dataStream.partition;

import org.apache.flink.api.common.functions.Partitioner;

/**
 * 自定义分区
 */
public class Mypartition implements Partitioner<Long> {
    @Override
    public int partition(Long o, int i) {
        // 第一个参数是值，第二个是tasknum
        return new Long(o%i).intValue();
    }
}
